const mysql = require('mysql');
const { MYSQL_CONFIG } = require('../configs/db');


// 创建连接池
const pool = mysql.createPool(MYSQL_CONFIG);

// 创建连接
const createConnection = () => {
    return new Promise((resolve, reject) => {
        pool.getConnection((err, connection) => {
            if (err) {
                reject(err);
            } else {
                resolve(connection);
            }
        });
    });
}

// 执行sql语句
const execSQL = (sql, values) => {
    return new Promise((resolve, reject) => {
        createConnection().then((connection) => {
            connection.query(sql, values, (err, results) => {
                if (err) {
                    reject(err);
                } else {
                    resolve(results);
                }
                connection.release();
            });
        });
    });
}

// 创建连接
// connection.connect();

// // 执行sql语句
// function execSQL(sql) {
//     console.log(connectTimeout);
//     return new Promise((resolve, reject) => {
//         connection.query(sql, (err, result) => {
//             if (err) {
//                 console.log('[SELECT ERROR] - ', err.message);
//                 reject(err);
//             } else {
//                 resolve(result);
//             }
//         });
//     });
// }

module.exports = {
    execSQL
};








